# 安装 celery
#pip install celery
#windows系统需要安装 eventlet
#pip install eventlet

#http://docs.celeryproject.org/en/latest/getting-started/brokers/redis.html
#task 任务
#broker 中间人 存储任务的队列
#worker 真正执行任务的工作者
#backend 存储任务执行后的结果

from celery import Celery
import time
celery = Celery("tasks",broker="redis://127.0.0.1:6379/0",backend="redis://127.0.0.1:6379/0")

@celery.task
def send_mail():
    print("邮件开始发送......")
    time.sleep(10)
    print("邮件发送结束.....")
